home *** CD-ROM | disk | FTP | other *** search
/ Windows Expert / Windows Expert.iso / windownt / queue.zip / QUEUE / QUEUE.H < prev    next >
C/C++ Source or Header  |  1992-10-11  |  5KB  |  147 lines
  1. /************************************************************************\
  2. * The enclosed files, "the software," is provided by 
  3. * Microsoft Corporation "as is" without warranty of any kind. 
  4. * MICROSOFT DISCLAIMS ALL WARRANTIES, EITHER EXPRESS OR IMPLIED, 
  5. * INCLUDING BUT NOT LIMITED TO IMPLIED WARRANTIES OF MERCHANTABILITY 
  6. * AND FITNESS FOR A PARTICULAR PURPOSE.  You assume all risks of 
  7. * using the software.
  8. * 
  9. * The software is Copyright (c) 1992 Microsoft Corporation.
  10. * Original Author: John M. Hall, Microsoft SDE  9/1/92
  11. *
  12. * You are granted the right to freely distribute this software.
  13. * You are granted the right to make changes provided this comment block
  14. * is retained without modification and you acknowledge the changes.
  15. * 
  16. \************************************************************************/
  17. /************************************************************************\
  18. *
  19. *                               QUEUE.H
  20. *
  21. \************************************************************************/
  22.  
  23. #ifndef QUEUE_DLL_H
  24. #define QUEUE_DLL_H
  25.  
  26. /************************************************************************\
  27. *                         SYMBOLIC CONSTANTS
  28. \************************************************************************/
  29.  
  30. #define QUE_INVALID_NAME      1000
  31. #define QUE_NO_MEMORY         1001
  32. #define QUE_NAME_NOT_EXIST    1002
  33. #define QUE_ELEMENT_NOT_EXIST 1003
  34. #define QUE_INVALID_HANDLE    1004
  35. #define QUE_EMPTY             1005
  36.  
  37. #define QUE_FIFO           1
  38. #define QUE_LIFO           2
  39. #define QUE_PRIORITY       3
  40.  
  41. #ifdef QUEUE_DLL_C
  42. #define INFINITE    0xFFFFFFFF
  43. #define MUNGE       37
  44. #define MAGIC       0x4a6d4800
  45. #define MAX_QUEUES  32
  46. #define QUEUE_LIMIT 100
  47.  
  48.  
  49. /************************************************************************\
  50. *                          GLOBAL SHARED VARIABLES
  51. \************************************************************************/
  52.  
  53. DWORD dwProcesses;
  54. int   iQueues;
  55.  
  56. /************************************************************************\
  57. *                          GLOBAL NON-Shared VARIABLES
  58. \************************************************************************/
  59.  
  60. HANDLE hMod       = NULL;
  61. HANDLE hGlobalSem = NULL;
  62. HANDLE hControl = NULL;
  63. LPVOID lpCtrlBase = NULL;
  64. DWORD  dwProcessID = 0;
  65. FILE *fp_log = NULL;
  66. LPBYTE lpBase = NULL;
  67.  
  68. /************************************************************************\
  69. *                          MACROS
  70. \************************************************************************/
  71. #define MAKE_PTR(a,b)  ((LPVOID)((DWORD)(a) + (b)))
  72. #define MUNGEIT(a) ( ((a)+1)* MUNGE)
  73. #define UNMUNGE(a) ( ((a)/MUNGE)-1)
  74.  
  75. #ifdef DEBUG
  76. #define AssertBox(a,b) if (!(a)) MyAssertBox((b), #a, __FILE__, __LINE__)
  77. #else
  78. #define AssertBox(a,b)
  79. #endif
  80.  
  81. #endif // QUEUE_DLL_C
  82. /************************************************************************\
  83. *                          STRUCTURES
  84. \************************************************************************/
  85.  
  86. typedef struct _queue_elem {
  87.     DWORD  dwWriterId;
  88.     DWORD  dwShrHandle;
  89.     DWORD  dwEventCode;
  90.     DWORD  dwPriority;
  91.  
  92. } Q_ELEMENT;
  93. typedef Q_ELEMENT *PQ_ELEMENT;
  94.  
  95. #ifdef QUEUE_DLL_C
  96. typedef struct {
  97.     DWORD  dwMagic;
  98.     DWORD  dwProcId;
  99.     HANDLE hEvent;
  100.     HANDLE hSem;
  101.     int    iIndex;
  102. } QUEUE;
  103. typedef QUEUE *HQUEUE;
  104. typedef HQUEUE *PHQUEUE;
  105.  
  106. typedef struct _queue_data {
  107.     DWORD  dwCreator;
  108.     WORD   wType;
  109.     ATOM   aQueueName;
  110.     short  sElements;  
  111.     Q_ELEMENT  elem[QUEUE_LIMIT];
  112. } QUEUE_DATA;
  113. typedef QUEUE_DATA *PQUEUE_DATA;
  114.  
  115. #else
  116.  
  117. typedef DWORD  HQUEUE;
  118. typedef HQUEUE *PHQUEUE;
  119.  
  120. #endif
  121.  
  122. /************************************************************************\
  123. *                         FLAGS
  124. \************************************************************************/
  125.  
  126. /************************************************************************\
  127. *                         FUNCTION PROTOTYPES
  128. \************************************************************************/
  129. VOID    MyAssertBox( const char *, const char *, const char *, int);
  130.  
  131. BOOL    QueueEntry (HANDLE hDLL, DWORD dwReason, LPVOID lpReserved);
  132. BOOL attach_ctl();
  133. BOOL IsValidHqueue( HQUEUE hqueue);
  134. DWORD CreateQueue( PHQUEUE phq, int fQueueOrder, LPTSTR pszName);
  135. DWORD CloseQueue( HQUEUE hq);
  136. DWORD OpenQueue(LPDWORD ppid, PHQUEUE phq, LPTSTR pszName);
  137. void push_down( int iIndex, int jj);
  138. void push_up( int iIndex, int jj);
  139. DWORD WriteQueue(HQUEUE hq, DWORD dwEventCode, DWORD dwShrHandle, DWORD dwPriority);
  140. DWORD ReadQueue(HQUEUE hq, PQ_ELEMENT pqe, int iElement, BOOL fWait);
  141. HANDLE GetQueueEventHandle( HQUEUE hqueue);
  142. DWORD  ShrFree(DWORD);
  143. DWORD PeekQueue(HQUEUE hq, PQ_ELEMENT pqe, int *piElement, BOOL fWait);
  144.  
  145.  
  146. #endif // QUEUE_DLL_H
  147.